ab8e17cc9c657b1d369dabb644f2d5e6d03c36b6,src/main/java/com/ociweb/pronghorn/network/NetGraphBuilder.java,NetGraphBuilder,buildHTTPTLSServerGraph,#boolean#GraphManager#number#number#number#ModuleConfig#number#,157
Before Change
WrapSupervisorStage wrapSuper = new WrapSupervisorStage(graphManager, tapMod, fromSuperPipes, coordinator);//ensure order
ServerSocketWriterStage writerStage = new ServerSocketWriterStage(graphManager, toWiterPipes, coordinator, g); //pump bytes out
GraphManager.addNota(graphManager, GraphManager.DOT_RANK_NAME, "SocketWriter", writerStage);
}
After Change
while (-- i>= 0) {
fromSuperPipes[i]=new Pipe<NetPayloadSchema>(fromWraperConfig);
}
toWiterPipes = fromSuperPipes;
}
Pipe[] tapMod = fromModule;//countTap(graphManager, fromModule, "Server-module-to-supervior");
WrapSupervisorStage wrapSuper = new WrapSupervisorStage(graphManager, tapMod, fromSuperPipes, coordinator, isTLS);//ensure order
Pipe[][] req = Pipe.splitPipes(socketWriters, toWiterPipes);
int w = socketWriters;
while (--w>=0) {
ServerSocketWriterStage writerStage = new ServerSocketWriterStage(graphManager, coordinator, req[w], g); //pump bytes out
GraphManager.addNota(graphManager, GraphManager.DOT_RANK_NAME, "SocketWriter", writerStage);
}